var mysql = require('mysql')
var errObj = require('./err');

module.exports = {
  // 通过前端传入配置连接数据库
  connect(cfj) {
    global.pool = mysql.createPool(cfj);
  },
  // 查询
  query(sql) {
    return new Promise((res, rej) => {
      // 数据库未连接
      if (!global.pool) {
        res({
          status: 2,
          msg: '请重新连接数据库后再重试！'
        })
      } else {
        global.pool.getConnection((err, connection) => {
          if (err) {
            // 连接错误
            res({ ...errObj.connFail, ...{ msg: err.message } })
          } else {
            connection.query(sql, (err, rows) => {
              if (err) {
                // 查询错误
                res({ ...errObj.SQLFail, ...{ msg: err.message } })
              } else {
                res({ ...errObj.success, ...{ aaData: rows } })
              }
              connection.release()
            })
          }
        })
      }
    })
  },
}